/**  
 * All rights Reserved, Designed By Suixingpay.
 * @author: chenfeifei[chen_ff@suixingpay.com] 
 * @date: 2017年9月21日 下午3:21:51   
 * @Copyright ©2017 Suixingpay. All rights reserved. 
 * 注意：本内容仅限于随行付支付有限公司内部传阅，禁止外泄以及用于其他的商业用途。
 */
package cn.hennancf.qieqie.mq.difficulty;

import java.io.IOException;
import java.io.Serializable;

import org.apache.commons.lang3.SerializationUtils;

/**  
 * 发送者
 * @author: chenfeifei[chen_ff@suixingpay.com]
 * @date: 2017年9月21日 下午3:21:51
 * @version: V1.0
 * @review: chenfeifei[chen_ff@suixingpay.com]/2017年9月21日 下午3:21:51
 */
public class Sender extends BaseConnector{
    
    public Sender(String queueName) throws IOException {
        super(queueName);
    }

    public void sendMessage(Serializable object) throws IOException {
        channel.basicPublish("",queueName, null, SerializationUtils.serialize(object));
    }  

}
